import fparser
import time

fp = fparser.FParser('en0')

while True:
    time.sleep(10)
    for flow in fp.flow_iter():
        if flow.get_info().Bps > 1000:
            print flow.get_id()

